package com.alibaba.datax.plugin.reader.aliyunslsreader.util;

import com.aliyun.openservices.loghub.client.config.LogHubConfig;

/**
 * Created by dancoder on 2022.01.08
 */
public class AliyunSlsUtil {
    public static LogHubConfig initLogHubConfig(String endpoint, String accessId, String accessKey, String project, String logstore, String consumeGroup) {
        return new LogHubConfig(consumeGroup, "consumer_1", endpoint, project, logstore, accessId, accessKey, LogHubConfig.ConsumePosition.BEGIN_CURSOR);
    }
}
